package com.lm.kafka.component;

import org.springframework.kafka.annotation.KafkaListener;
import org.springframework.stereotype.Component;

@Component
public class KafkaConsumerService {

    @KafkaListener(topics = "test-top", groupId = "test-group")
    public void listen(String message) {
        System.out.println("接收到 Kafka 消息: " + message);
    }
}
